package ex.datastream.functions.richFunction;

import ex.vo.ComplexPojo;
import org.apache.flink.api.common.functions.RichMapFunction;

public   class RichMapFunc extends RichMapFunction<ComplexPojo,Integer> {

    @Override
    public Integer map(ComplexPojo pojo) throws Exception {
        Integer sum =0;
        int[] list = pojo.getArray();
        for(int i : list) {
            sum =sum+i;
        }
        return sum;
    }
}